import pymysql

#1.建立数据库连接
connect = pymysql.connect(
    # MySQL数据库的IP地址，默认127.0.0.1（代表本地）
    host='127.0.0.1',
    # MySQL数据库的用户名
    user='root',
    # MySQL数据库的密码
    password='123456',
    # MySQL数据库服务的端口号；默认为3306
    port=3306,
    # 数据库名称
    db='spider',
    # 字符编码
    charset='utf8'
)
#2.使用cursor()方法获取操作游标
cursor = connect.cursor()
#3.查询products表
#查询数据SQL语句
selectSql = "SELECT * FROM products where avg_price > 1"
try:
   # 执行sql语句
   cursor.execute(selectSql)
   # 获取所有记录列表
   results = cursor.fetchall()
   # 循环遍历
   for row in results:
       id = row[0]
       topClass = row[1]
       secClass= row[2]
       productName = row[3]
       lowPrice= row[4]
       avgPrice = row[5]
       highPrice = row[6]
       specs = row[7]
       origin = row[8]
       unti= row[9]
       updateTime = row[10]

       # 打印结果
       print("id=%s, 大类=%s, 小类=%s, 产品名称=%s, 最低价=%s,"
             "平均价=%s, 最高价=%s, 规格=%s, 来源=%s, 单位=%s,更新日期=%s"
             %(id, topClass, secClass, productName, lowPrice,
               avgPrice, highPrice, specs, origin, unti, updateTime))

except:
        # 发生异常，控制台输出
        print("获取数据失败！")

#4.关闭数据库连接
connect.close()
